9b76bd8b46da92072c1f8a38b1234988a8e6c0d5,gateway/src/main/java/com/continuuity/gateway/v2/handlers/stream/CachedStreamEvents.java,ProducerStreamEntries,flush,#,177
Before Change
new StreamEntryToQueueEntryFunction(future, callbackExecutorService);
try {
streamEntries.drainTo(entries);
if (entries.isEmpty()) {
return;
}
After Change
public synchronized void flush() {
List<StreamEntry> entries = Lists.newArrayListWithExpectedSize(streamEntries.size());
streamEntries.drainTo(entries);
if (entries.isEmpty()) {
return;
}